import cache
from dao.commonDao import ChatMsg
from protoc import IMProto_pb2

def process(head,msgBody):
    ack = IMProto_pb2.Ack()
    ack.ParseFromString(msgBody)

    msg = ChatMsg()
    msg.sessionId = ack.sessionId
    msg.msgId = ack.msgId
    msg.seqId = ack.seqId
    cache.Cache.dao.updateMsg(msg)

    ack_ = {
        'msgId':ack.msgId,
        'sessionId':ack.sessionId,
        'seqId':ack.seqId
    }
    cache.Cache.app.msgObject.ackMsg(ack_)